package com.bangcommunity.bbframe.mq;

import com.bangcommunity.bbframe.mq.consumer.IQtMsgProcessor;
import com.bangcommunity.bbframe.mq.producer.IQtProducer;

import java.util.Properties;

/**
 * Created by tanghc on 17/2/4.
 */
public interface IQtMqFactory {
    IQtProducer builderPruduer();

    Runnable builderConsumer(String rawTopic, IQtMsgProcessor msgProcessor);

    Runnable builderConsumer(String projectCode, String appCode, String topic, IQtMsgProcessor msgProcessor);

    Runnable builderConsumer(String rawTopic, Properties properties, IQtMsgProcessor msgProcessor);

    Runnable builderConsumer(String projectCode, String appCode, String topic, Properties properties,
            IQtMsgProcessor msgProcessor);
}
